package com.wondertek.poms.sync.config;

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import com.wondertek.poms.common.constant.Constants;

/**
 * <p><b>RabbitmqConfig Description:</b> rabbitmq配置</p>
 * @author douzi
 * <b>DATE</b> 2020年12月10日 上午10:03:03
 */
@Configuration
public class RabbitmqConfig {

	@Bean
    public Queue contentQueue() {
        return new Queue(Constants.QUEUE_SYNC_CONTENT);
    }

    @Bean
    public Queue pomsNewQueue() {
        return new Queue(Constants.QUEUE_NEW_POMS_SYNC);
    }

    @Bean
    public Queue transImgQueue() {
        return new Queue(Constants.QUEUE_TRANS_IMG);
    }

    @Bean
    public Queue publishQueue() {
        return new Queue(Constants.QUEUE_SYNC_PUBLISH);
    }

    @Bean
    Queue delayQueue() {
        return new Queue(Constants.QUEUE_SLOW_SYNC_CONTENT);
    }
    
    @Bean
    Queue imgQueue() {
    	return new Queue(Constants.QUEUE_TRANS_IMG_BACK);
    }
    
    @Bean
    Queue esPrdQueue() {
    	return new Queue(Constants.QUEUE_ES_PRD_CONT);
    }
}
